package com.example.sourcecodelearning.modules.mq;

import cn.hutool.json.JSONObject;
import com.example.framework.mq.rocketmq.core.service.RocketMQConsumerService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class RocketMQService extends RocketMQConsumerService<JSONObject> {

    @Override
    public void consume(String topic, JSONObject msgBody) {
        log.info("消费rocket mq消息，topic={}, msgBody={}", topic, msgBody);
    }
}
